const mysql = require('mysql');
module.exports = {
    // 数据库配置
    config: {
        host: "localhost",
        port: "3306",
        user: "root",
        password: "48625",
        database: "blog"
    },
    // 连接数据库，使用连接池的方式
    // 连接池对象
    sqlConnect: function (sql, sqlArr, callback) {
        var pool = mysql.createPool(this.config);
        pool.getConnection((err, conn) => {
            console.log("数据库连接池");
            if (err) {
                console.log("连接失败");
                return;
            } else {
                console.log("连接成功...");
            }
            // 事件驱动回调
            conn.query(sql, sqlArr, callback);
            // 释放连接
            conn.release();
        })
    },
    //promise 回调
    SySqlConnect: function (sySql, sqlArr) {
        return new Promise((resolve, reject) => {
            var pool = mysql.createPool(this.config);
            pool.getConnection(function (err, conn) {
                console.log('123');
                if (err) {
                    reject(err);
                } else {
                    conn.query(sySql, sqlArr, (err, data) => {
                        if (err) {
                            reject(err)
                        } else {
                            resolve(data);
                        }
                        conn.release();
                    });
                }

            })
        }).catch((err) => {
            console.log(err);
        })
    }
}